package com.多用户通讯编程.QQ.Client.Service;

import java.util.HashMap;
import java.util.concurrent.ConcurrentHashMap;

@SuppressWarnings("all")
/**
 *  管理用户通讯的线程集合类；
 */
public class ManageClientConnectServerThread {
    /// 用来存放客户端通讯线程，将用户Userid和用户通讯的线程放进来；
    private static ConcurrentHashMap<String , ClientConnectServerThread> map = new ConcurrentHashMap<>();

    /// 添加功能
    public static  void put(String UserId , ClientConnectServerThread ccst){
        map.put(UserId , ccst);
    }

    /// 通过用户获取对应线程；
    public static  ClientConnectServerThread get(String UserId){
        return map.get(UserId);

    }
    /// 删除线程
    public static  void remove(String UserId){
        map.remove(UserId);

    }


}
